package cn.lingyangwl.agile.demo.mq_sequence;

import java.util.function.Consumer;

/**
 * @author shenguangyang
 */
public interface MqDataService {
    void test() throws InterruptedException;

    void processSequence(MqData mqData, Consumer<MqData> consumer);
}
